package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.SfaBinderConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;
/**
 * sfa 消息队列
 * @author 魏荣杰
 * @date 2019/2/22 18:58
 * @since v1.0
 * @version v1.0
 */
@Service("sfaProducerBinder")
public interface SfaProducerBinder {
    /**
     * 客户
     */
//    @Input(SfaBinderConstant.SFA_CUSTOMER_INPUT)
//    SubscribableChannel sfaCustomerInput();
    @Output(SfaBinderConstant.SFA_CUSTOMER_OUTPUT)
    MessageChannel sfaCustomerOutput();
    /**
     * 销售机会
     */
//    @Input(SfaBinderConstant.SFA_OPPORTUNITY_INPUT)
//    SubscribableChannel sfaOpportunityInput();
    @Output(SfaBinderConstant.SFA_OPPORTUNITY_OUTPUT)
    MessageChannel sfaOpportunityOutput();
    /**
     * 合同
     */
//    @Input(SfaBinderConstant.SFA_CONTRACT_INPUT)
//    SubscribableChannel sfaContractInput();
    @Output(SfaBinderConstant.SFA_CONTRACT_OUTPUT)
    MessageChannel sfaContractOutput();
    /**
     * 联系人
     */
//    @Input(SfaBinderConstant.SFA_CONTACT_INPUT)
//    SubscribableChannel sfaContactInput();
    @Output(SfaBinderConstant.SFA_CONTACT_OUTPUT)
    MessageChannel sfaContactOutput();
}
